package cn.com.tt.flink.sql.engine.pojo.sql;

import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

public class BmDdlSql extends AbstractBmFlinkSql {


    public BmDdlSql(String sqlStatement, StreamTableEnvironment tableEnv) {
        super(sqlStatement, tableEnv);
    }


    @Override
    protected void innerProcess() {
        tableEnv.executeSql(sqlStatement);
    }
}
